package com.ease.integration.jms.support;

import javax.jms.XAQueueConnectionFactory;
import javax.sql.XADataSource;

import oracle.jms.AQjmsFactory;

public class OracleAqConnectionFactoryFactory {
	private XADataSource dataSource = null;

	public XAQueueConnectionFactory createConnectionFactory() throws Exception {
		return AQjmsFactory.getXAQueueConnectionFactory(dataSource);
	}

	public XADataSource getDataSource() {
		return dataSource;
	}

	public void setDataSource(XADataSource dataSource) {
		this.dataSource = dataSource;
	}

}
